package com.csdn.eval.spring.mqtt.core;

import lombok.extern.slf4j.Slf4j;
import org.springframework.messaging.MessageHeaders;

@Slf4j
public class DefaultDispatcherMessageHandler<T> implements MessageHandlerService<T> {
    @Override
    public void doHandleMessage(String topic, byte[] message, MessageHeaders headers) {
        // 默认处理器，什么都不做
        // 可以在这里添加日志或其他默认行为
        log.debug("DefaultDispatcherMessageHandler received message on topic: " + topic);
        log.debug("Message content: " + new String(message));
        log.debug("Message headers: " + headers);
    }
}
